0206f6ee37133c41b7f64c80eff45e3482a4c84b,cdap-unit-test/src/test/java/co/cask/cdap/test/app/TestFrameworkTestRun.java,TestFrameworkTestRun,testMapperDatasetAccess,#,128
Before Change
ApplicationManager appManager = deployApplication(DatasetWithMRApp.class);
Map<String, String> argsForMR = ImmutableMap.of(DatasetWithMRApp.INPUT_KEY, "table1",
DatasetWithMRApp.OUTPUT_KEY, "table2");
MapReduceManager mrManager = appManager.getMapReduceManager(DatasetWithMRApp.MAPREDUCE_PROGRAM);
mrManager.start(argsForMR);
mrManager.waitForFinish(5, TimeUnit.MINUTES);
appManager.stopAll();
After Change
tableManager.flush();
ApplicationManager appManager = deployApplication(DatasetWithMRApp.class);
Map<String, String> argsForMR = ImmutableMap.of(DatasetWithMRApp.INPUT_KEY, "table1",
DatasetWithMRApp.OUTPUT_KEY, "table2");
MapReduceManager mrManager = appManager.getMapReduceManager(DatasetWithMRApp.MAPREDUCE_PROGRAM).start(argsForMR);
mrManager.waitForFinish(5, TimeUnit.MINUTES);
appManager.stopAll();